package com.clound.order.message;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * Created by zzy on 2018/4/12.
 */
public interface StreamClient {

    String INPUT="myMessage";

    String INPUT2="myMessage2";

/*    @Input(StreamClient.INPUT)
    SubscribableChannel input();*/

    @Output(StreamClient.INPUT)
    MessageChannel output();

    @Output(StreamClient.INPUT2)
    MessageChannel output2();
}
